package comandos;

import model.Usuario;
import protocol.MensajeComando;
import server.ClienteHilo;

public class MensajeChat implements ComandoServidor
{
	private String mensaje;
	private Integer conversacionId;
	private Usuario usuarioOrigen;
	
	public void ejecutar (ClienteHilo cliente)
	{

			try	{
				System.out.println("Conversaciones - Enviando mensaje a " + cliente.getUsuario() + " " + mensaje);

				//Envio el comando
				cliente.getOutput().writeObject(new MensajeComando("enviar_mensaje_chat",1));
				cliente.getOutput().flush();
				
				//Envio el mensaje a su destino.
				cliente.getOutput().writeObject(new String(usuarioOrigen + " dice: " + this.mensaje));
				cliente.getOutput().flush();	
				
				//Envio el mensaje a su destino.
				cliente.getOutput().writeObject(conversacionId);
				cliente.getOutput().flush();	
				
			}catch (Exception e){
				e.printStackTrace();
				System.out.println("Problema al ejecutar el comando");
			}		

	}
	
	public String getMensaje() {
		return mensaje;
	}
	public void setMensaje(String mensaje) {
		this.mensaje = mensaje;
	}

	public Usuario getUsuarioOrigen() {
		return usuarioOrigen;
	}

	public void setUsuarioOrigen(Usuario usuarioOrigen) {
		this.usuarioOrigen = usuarioOrigen;
	}

	public Integer getConversacionId() {
		return conversacionId;
	}

	public void setConversacionId(Integer conversacionId) {
		this.conversacionId = conversacionId;
	}
	
	
}
